package com.ict.dataprocess;

import com.ict.config.Config;
import com.ict.utils.MQTopicConsume;

public class OrigFirstThread  extends Thread {
	private boolean  isStop=false;
	public void  run() {
		
		System.out.println("first  start");
		String []  rountingKey= {Config.origTargetRoutingKey};
		 MQTopicConsume mqTopicConsume = new MQTopicConsume(Config.recvMQIP, Config.recvMQPort, Config.recvMQUserName, Config.recvMQPasswd,
	                "xgs", rountingKey,"xgs_tap_by_tlc");
		 mqTopicConsume.ConsumeOrig();
		
	}
	public void  isStop(boolean stopFlag) {
		this.isStop=stopFlag;
	}
	

}
